/*
package com.cowain.monitor.listener;

import com.alibaba.otter.canal.protocol.CanalEntry;
import com.xpand.starter.canal.annotation.CanalEventListener;
import com.xpand.starter.canal.annotation.ListenPoint;

*/
/**
 *  
 *  * @author 冬暖
 *  * @projectName pms-monitor
 *  * @title     ApplicationListener   
 *  * @package    com.cowain.monitor.listener  
 *  * @description    预测申请单监听       
 *  * @date   2020/7/27 10:15  
 *  * @version V1.0.0
 *  
 *//*

@CanalEventListener  //canal监听类
public class ApplicationListener {
    */
/**
     * 监听的表数据变化
     * @param entryType 类型
     * @param rowData 数据
     *//*

    @ListenPoint(schema = "ehr-pms",table = "pms_forecast_application")
    public void insert(CanalEntry.EntryType entryType,CanalEntry.RowData rowData){
        System.out.println("预测申请单数据发生改变之前");
        //获取改变前的数据
        rowData.getBeforeColumnsList().forEach(c -> System.out.println("改变前的数据: " + c.getName() + "::" + c.getValue()));
        //数据库中表中的字段名以及对应的字段值

        //获取改变之后的数据
        rowData.getAfterColumnsList().forEach(c -> System.out.println("改变之后的数据:" + c.getName() + "::" +c.getValue()));
    }
}
*/
